package com.camemax.rabbitmq.headers_mode.queueddl;

import com.camemax.rabbitmq.utils.QueueModulesRunnable;

import java.util.HashMap;
import java.util.Map;

public class HeadersMode_CreateQueues extends QueueModulesRunnable {
    public HeadersMode_CreateQueues(String queueName, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments) {
        super(queueName, durable, exclusive, autoDelete, arguments);
    }

    public static void main(String[] args) {
        Map<String, Object> headersType = new HashMap<>();
        headersType.put("type", "HEADERS");

        Map<String, Object> headersAuthor = new HashMap<>();
        headersAuthor.put("author", "CAMEMAX");

        Map<String, Object> headersTag = new HashMap<>();
        headersTag.put("tag", "RabbitMQ");
        new Thread(new HeadersMode_CreateQueues(
                "headers-queue01",
                true,
                false,
                false,
                headersType
        ), "headers-queue01").start();
        new Thread(new HeadersMode_CreateQueues("headers-queue02",
                true,
                false,
                false,
                headersAuthor
        ), "headers-queue02").start();
        new Thread(new HeadersMode_CreateQueues("headers-queue03",
                true,
                false,
                false,
                headersTag
        ), "headers-queue03").start();
    }
}
